from elasticsearch import Elasticsearch

es_url = "106.13.117.37"
port = 9200


class DataBase:
    client: Elasticsearch = None


conn: DataBase = DataBase()


async def connect_to_es():
    print('连接es数据库ing')
    conn.client = Elasticsearch(host=es_url, port=port)
    print("数据库连接成功")
